package com.fast.task.kafka;

import org.apache.kafka.clients.consumer.ConsumerRecord;

public interface IKafkaConsumerService {

	void onMessage(ConsumerRecord<Integer, String> record);

}